package com.zhuoyue.common.mqtt;

import com.zhuoyue.common.mqtt.util.MqttUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author Administrator
 */
@Component
public class MqttDataHandle {
    @Autowired
    private MqttUtil mqttUtil;

    /**
     * 无数据库操作基础推送
     *
     * @param topic
     * @param message
     */
    public void basePush(String topic, String message) {
        mqttUtil.publish(topic, message, 0);
    }
}
